package com.yanggu.bigdata.realtime.app

import com.alibaba.fastjson.JSONObject
import org.apache.flink.streaming.api.scala._

//case object和object之间的最大区别在于case object自动实现了Serializable接口可以进行序列化
//flink需要所有的类都能够序列化
case object OutputTagObject {

  /**
   * 解析错误数据的标记
   */
  val errorJsonDataOutputTag: OutputTag[String] = OutputTag[String]("errorJsonDataOutputTag")

  /**
   * 启动日志的标记
   */
  val startLogOutputTag: OutputTag[String] = OutputTag[String]("startLogOutputTag")

  /**
   * 曝光日志的标记
    */
  val displayOutputTag: OutputTag[String] = OutputTag[String]("displayOutputTag")

  /**
   * 动态分流中, 业务数据DIM, 维度表数据放入hbase的标记
   */
  val dimHbaseOutputTag: OutputTag[JSONObject] = OutputTag[JSONObject]("dimHbaseOutputTag")

}
